package com.bigdata.quality.config.connector;

import com.bigdata.quality.config.enums.DatabaseEnums;
import lombok.Data;

import java.util.List;

@Data
public class ConnectorParams {

  // 封装Flink Table create table 需要的参数
  private String tableName;

  // name和type长度和位置必须一致
  private List<String> columnNameList;
  private List<String> columnFlinkTypeList;

  // 封装Flink Table with段落需要的参数
  //
  private DatabaseEnums databaseEnums;
  // 扩展配置JSON
  private String expandSettings;
  private String jdbcUrl;
  private String username;
  private String password;
  private String driverClass;
  private String databaseName;
  private String host;
  private String port;
  private String tenant;

}
